//package com.jyl.connecter.server.custom;
//
//import com.jyl.connecter.config.TaskProto;
//import io.netty.buffer.ByteBuf;
//import io.netty.buffer.Unpooled;
//import io.netty.channel.ChannelHandlerContext;
//import io.netty.handler.codec.MessageToByteEncoder;
//
//public class ProtobufEncoder extends MessageToByteEncoder<TaskProto.Task> {
//    @Override
//    protected void encode(ChannelHandlerContext channelHandlerContext, TaskProto.Task task, ByteBuf out) throws Exception {
//
//        //将对象转换为byte
//        byte[] bytes = task.toByteArray();
//
//        //读取消息长度
//        int length = bytes.length;
//
//        ByteBuf buffer = Unpooled.buffer(2 + length);
//
//        //先将消息长度写入，也就是消息头
//        buffer.writeShort(length);
//
//        //消息体中包含我们要发送的数据
//        buffer.writeBytes(bytes);
//
//        out.writeBytes(buffer);
//
//    }
//}
